package org.zhadoop.streaming.operator;

import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.xml.sax.InputSource;
import org.zhadoop.streaming.event.IEventType;
import org.zhadoop.streaming.event.TupleEvent;
import org.zhadoop.streaming.exception.StreamingException;
import org.zhadoop.streaming.serde.StreamSerDe;

import com.google.common.collect.Lists;
import com.google.common.collect.Maps;

/**
 * 最基础的输出输出算子
 * @author zwd
 *
 */
public class OutputOperator extends AbsOperator{

	/**
	 * 
	 */
	private static final long serialVersionUID = -6694055801791254946L;

	private static final Logger LOG = LoggerFactory.getLogger(OutputOperator.class);
	
	private StreamSerDe serde;
	
	private List<String> inputStreams;
	
	private Map<String,IEventType> inputSchemas;
	
	private IOutputStreamOperator outputStream;
	
	public OutputOperator() {
		inputStreams = Lists.newArrayList();
		inputSchemas = Maps.newHashMap();
	}
	
	
	@Override
	public List<String> getInputStream() {
	
		return null;
	}

	@Override
	public String getOutputStream() {
		// TODO Auto-generated method stub
		return null;
	}

	@Override
	public Map<String, IEventType> getInputSchema() {
		// TODO Auto-generated method stub
		return null;
	}

	@Override
	public IEventType getOutputSchema() {
		// TODO Auto-generated method stub
		return null;
	}

	@Override
	public Map<String, GroupInfo> getGroupInfo() {
		// TODO Auto-generated method stub
		return null;
	}

	@Override
	public void execute(String streamName, TupleEvent event) throws StreamingException {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void destory() throws StreamingException {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void initialize() throws StreamingException {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void setInputStream(List<String> streamNames) throws StreamingException {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void setOutputStream(String streamName) throws StreamingException {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void setInputSchema(Map<String, IEventType> schemas) throws StreamingException {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void setOutputSchema(IEventType schema) throws StreamingException {
		// TODO Auto-generated method stub
		
	}

}
